package com.dh.order.message;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.stereotype.Component;

import lombok.extern.slf4j.Slf4j;

/**
 * @author 作者 dinghao
 * @version 创建时间：2018年11月19日 上午10:51:33
 * @Description 类说明 :
 */
@Component
@EnableBinding(StreamClient.class)
@Slf4j
public class StreamReceiver {

//	@StreamListener(StreamClient.INPUT)
//	public void process(Object message) {
//		log.info("StreamReceiver {}", message);
//	}
}
